package com.xunkids.bos.migration.component.transmission.kafka;


import com.xunkids.bos.migration.common.exception.RushException;
import com.xunkids.bos.migration.component.transmission.api.QueuePublisher;

/**
 * kafka 发布
 *
 * @author xigexb
 * @version 1.0.0
 * @since 2021/12/28 21:11
 */
public interface KafkaPublisher extends QueuePublisher {

    /**
     * 发布消息
     *
     * @param topic 主题
     * @param data  消息
     */
    void send(String topic, String data) throws RushException;

}